package com.daoserver.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface InPutBarista {
	
	/**
	 * 通道名
	 * 
	 * 通道名发送方和接受方必须是一致的
	 * 一个应用不能既是同一个通道的发送方和接收方，否则会警告。
	 * 
	 * 
	 * 这一名字与配置文件中send_msg应该一致，表明注入了一个名字叫做send_msg的通道
	 */
	String INPUT_MESSAGE_CHANNEL = "send_msg";

	@Input(InPutBarista.INPUT_MESSAGE_CHANNEL)
	SubscribableChannel refreshUserCacheMessage();
	
	
}
